package com.hyperboost.deepseek.assistant;

import dev.langchain4j.service.MemoryId;
import dev.langchain4j.service.SystemMessage;
import dev.langchain4j.service.UserMessage;
import dev.langchain4j.service.spring.AiService;
import reactor.core.publisher.Flux;

@AiService(chatMemoryProvider = "chatMemoryProvider")
public interface DeepSeek {

    /**
     * DeepSeek流式对话
     * @param memoryId 对话Id
     * @param userMessage 聊天信息
     * @return
     */
    @SystemMessage(fromResource = "deepseek-prompt.txt") // 设置系统提示语
    Flux<String> chat(@MemoryId Long memoryId, @UserMessage String userMessage);

    /**
     * DeepSeek响应式对话
     * @param memoryId 对话Id
     * @param userMessage 聊天信息
     * @return
     */
    // String chat(@MemoryId Long memoryId, @UserMessage String userMessage)
}
